package com.etl.dataflow.executor.core;

/**
 * @author dx
 * @since 2022/4/21
 */
public interface Reader {
    boolean startRead();

    void exit();

    long getRowCount();

    long getRedRowNumber();

    void setOnReadErrorListener(OnReadErrorListener listener);

    void setAfterReadInterceptor(AbstractAfterReadInterceptor interceptor);

    interface OnReadErrorListener {
        void onError(Exception e);
    }
}
